Using RxJS in Angular with conditional